package com.potenza.service;

//@Component
public class KafkaStreamListener {

    //@KafkaListener(topics = "StreamTopic")
    public void onMessage2(String message) {
        // 处理
        System.out.println("Stream处理之前的"+message);
    }

    //@KafkaListener(topics = "AnotherTopic")
    public void onMessage1(String message) {
        // 处理
        System.out.println("Stream处理之后的"+message);
    }


}